# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator
from jms.dwd.oms.dwd_yl_oms_oms_waybill_incre_dt import jms_dwd__dwd_yl_oms_oms_waybill_incre_dt
from jms.dwd.tab.dwd_tab_reback_transfer_express_base import jms_dwd__dwd_tab_reback_transfer_express_base
from jms.dim.dim_yl_oms_order_interceptor_base import jms_dim__dim_yl_oms_order_interceptor_base
from jms_bigdata_platform.dwd.dwd_wide_summary_waybill import jms_dwd__dwd_wide_summary_waybill
from jms.dwd.tab.dwd_tab_barscan_difficult_base_dt import jms_dwd__dwd_tab_barscan_difficult_base_dt
from jms.dim.dim_lmdm_sys_first_code import jms_dim__dim_lmdm_sys_first_code
from jms.dim.dim_lmdm_sys_second_code import jms_dim__dim_lmdm_sys_second_code
from jms.dim.dim_network_whole_massage import jms_dim__dim_network_whole_massage

oss_dm_network_no_reguler_reback_register_dt = BashOperator(
    task_id='oss_dm_network_no_reguler_reback_register_dt',
    email=['wangmenglei@jtexpress.com','yl_bigdata@yl-scm.com'],
    pool='unlimited_pool',
    bash_command='jms/oss/dm_network_no_reguler_reback_register_dt/execute.sh',
    execution_timeout=timedelta(minutes=50),
    sla=timedelta(hours=7)
)

oss_dm_network_no_reguler_reback_register_dt << [
    jms_dwd__dwd_yl_oms_oms_waybill_incre_dt ,
    jms_dwd__dwd_tab_reback_transfer_express_base,
    jms_dim__dim_yl_oms_order_interceptor_base,
    jms_dwd__dwd_wide_summary_waybill,
    jms_dwd__dwd_tab_barscan_difficult_base_dt,
    jms_dim__dim_lmdm_sys_first_code,
    jms_dim__dim_lmdm_sys_second_code,
    jms_dim__dim_network_whole_massage
]
